package net.unix8.share;

import java.util.Vector;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.util.concurrent.GlobalEventExecutor;
import net.unix8.bean.GetDataBean;
import net.unix8.bean.WaveDataNoSql;
import net.unix8.bean.WaveStationNoSql;
public class NetworkShare {
	//public  static ConcurrentHashMap<String, ChannelHandlerContext> clientMap = new ConcurrentHashMap<String, ChannelHandlerContext>();  
	public  static ExecutorService taskPool = Executors.newCachedThreadPool();
	public static ChannelGroup clientGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
	public static Vector<WaveStationNoSql> stations = new  Vector<WaveStationNoSql>();
	public static Vector<WaveDataNoSql> datas = new  Vector<WaveDataNoSql>();
	public static String startTime;
	public static ArrayBlockingQueue<GetDataBean> getDataQueue = new ArrayBlockingQueue<GetDataBean>(200);
	public static String paodianHost = "";
}
